From: Jeroen van der Heijden Date: Tue, 15 Sep 2020 12:07:33 +0000 (+0200) Subject: Update test insert X-Git-Tag: archive/raspbian/2.0.44-1+rpi1~1^2~3^2~2^2~14^2 X-Git-Url: https://dgit.raspbian.org/%22http://www.example.com/cgi/success/%22http:/www.example.com/cgi/success?a=commitdiff_plain;h=9acb8601613b5b6d944394544cd61668e599f09a;p=siridb-server.git Update test insert --- diff --git a/itest/test_insert.py b/itest/test_insert.py index 6dcbc20d..bc0aebb0 100644 --- a/itest/test_insert.py +++ b/itest/test_insert.py @@ -165,19 +165,19 @@ class TestInsert(TestBase): await self.assertSeries(self.client0, series) await self.assertSeries(self.client1, series) - # tasks = [ - # asyncio.ensure_future(self.client0.query( - # 'drop series /.*/ set ignore_threshold true')) - # for i in range(5)] + tasks = [ + asyncio.ensure_future(self.client0.query( + 'drop series /.*/ set ignore_threshold true')) + for i in range(5)] - # await asyncio.gather(*tasks) + await asyncio.gather(*tasks) - # tasks = [ - # asyncio.ensure_future(self.client0.query( - # 'drop shards set ignore_threshold true')) - # for i in range(5)] + tasks = [ + asyncio.ensure_future(self.client0.query( + 'drop shards set ignore_threshold true')) + for i in range(5)] - # await asyncio.gather(*tasks) + await asyncio.gather(*tasks) await asyncio.sleep(2)